package com.heisenhub.common.mq.manager;

import com.heisenhub.common.mq.model.BaseMessage;
import com.heisenhub.common.mq.utils.RocketMQUtils;
import com.heisenhub.common.mq.service.MqService;

public class RocketMqManager implements MqService {
    @Override
    public void sendMessage(String topic, BaseMessage message) {
        RocketMQUtils.sendMessage(topic,message);
    }

    @Override
    public void sendMessage(String topic, String tags, BaseMessage message) {
        RocketMQUtils.sendMessage(topic,tags,message);
    }

    @Override
    public void sendDelayed(String topic, BaseMessage message, int delayLevel) {
        RocketMQUtils.sendDelayed(topic,message ,delayLevel);
    }

    @Override
    public void sendDelayed(String topic, String tags, BaseMessage message, int delayLevel) {
        RocketMQUtils.sendDelayed(topic,tags,message ,delayLevel);
    }
}
